#pragma once
#include "stdafx.h"
#include "Operator.h"
#include "WindowSynopsis.h"
#include "QueueEntity.h"
#include <boost/shared_ptr.hpp>
class RowWindowOperator:public Operator
{
private:
	const int rowWindowSize;
	int currentRowNumberInSynopsis;
	boost::shared_ptr<WindowSynopsis> windowSynopsis; 
	Timestamp lastInputTimestamp;
	Element blockedElement;
public:
	RowWindowOperator(int rowWindowSize);
	~RowWindowOperator(void);
	
    void execution(int executionTimes);
	void dealWithBlock(void);
};

